package concurrent.pool;

/**
 * 拒绝策略，通过实现reject方法来实现自定义拒绝策略
 * @author Jay
 * @param <T>
 */
@FunctionalInterface
public interface RejectPolicy<T> {
    /**
     * 实现该方法作为拒绝策略
     * @param queue 阻塞队列
     * @param task 当前任务
     */
    void reject(BlockingQueue<T> queue, T task);
}
